package com.yytek.job.fegin;

import com.yytek.common.core.constant.ServiceNameConstants;
import com.yytek.common.core.constant.ValueConstant;
import com.yytek.common.core.domain.CommandRequest;
import com.yytek.common.core.domain.R;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;


@FeignClient(contextId = "mqttService", value = ServiceNameConstants.GW_MQTT_SERVICE)
public interface MqttFegin {

    /**
     * MQTT写入
     * @param commandRequest
     * @return
     */
    @PostMapping(ValueConstant.Driver.COMMAND_URL_PREFIX+"/write")
    R write(@RequestBody CommandRequest commandRequest);

}
